package utils

import (
	"fmt"
	"gitee.com/hakwolf/dbmagic/golib/internal/modules/configdbg"
	"os"
)

const (
	SqlsT  = 1
	MysqlT = 2
)

type DbTaskResponse struct {
	Output string `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"` // 命令标准输出
	Error  string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`   // 命令错误
}

type DbtaskrequestFtp struct {
	Dip  string // 命令
	Port int64
	Ac   string
	Pd   string
}

type DbTaskRequest struct {
	Local   string
	Dbname  string
	Port    int64
	Dip     string
	Ac      string
	Pd      string
	Dtype   int32
	Sqlpath string
	Timeout int32 // 任务执行超时时间
	Id      int64 // 执行任务唯一ID
	Ftp     []*DbtaskrequestFtp
}

// 检测目录是否存在
func CreateDirIfNotExistsbak(path ...string) {
	for _, value := range path {
		if FileExist(value) {
			continue
		}
		err := os.Mkdir(value, 0755)
		if err != nil {
			//logger.Fatal(fmt.Sprintf("创建目录失败:%s", err.Error()))
			configdbg.Println(fmt.Sprintf("创建目录失败:%s", err.Error()))
		}
	}
}

func CreateDirIfNotExists(path string) {
	err := os.MkdirAll(path, os.ModePerm)
	if err != nil {
		//logger.Fatal(fmt.Sprintf("创建目录失败:%s", err.Error()))
		configdbg.Println(fmt.Sprintf("创建目录失败:%s", err.Error()))
	}
}
